package com.zjc.kafka.embedded;

import java.util.Properties;

public interface EmbeddedKafka {

    EmbeddedKafka start();
    void stop() throws Exception;

    String getBrokerConnectionString();

    Properties getStandardProperties();

}
